import os

import django
from celery import Celery
from dotenv import load_dotenv
# 设置 Django 环境变量
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "seckill_java_topy.settings")

# 初始化 Django
django.setup()
# from django.conf import settings
# print("INSTALLED_APPS:", settings.INSTALLED_APPS)
# 创建 Celery 实例
celery = Celery(
    "fastapi_seckill",
    broker="amqp://guest:guest@192.168.141.16:5672",  # 使用 Redis 作为 Broker
    backend="redis://192.168.141.15:6379/4"  # 使用 Redis 作为 Result Backend
)

# 自动发现任务模块
celery.autodiscover_tasks(["fastapi_seckill"])